#coding=utf8

import gevent
import abu.rpc

class ServiceStub(abu.rpc.Proxy):
	def __init__(self,ip,port,stub_type):
		conn = gevent.socket.create_connection((ip,port))
		channel = abu.rpc.Channel(abu.rpc.Transport(conn))
		super(ServiceStub,self).__init__(stub_type(channel))
